package com.qiaofang.collectmanage.dao.constant;

public final class ConstantProperties {


    String APPLICATION_PROPERTIES = "application.properties";
    /**
     * spark程序常量
     */
    String HOUSE_INCR_TOPIC = "house.incr.topic";
    //rentalhouse
    String RENTAL_LOCAL = "rental.local";
    String RENTAL_STREAMING_BATCH_DURATION = "rental.streaming.batchDuration";
    String RENTAL_STREAMING_CHECKPOINT_PATH = "rental.streaming.checkpoint.path";
    String RENTAL_STOP_PATH = "rental.stop.path";
    String RENTAL_KAFKA_MAX_RATE_PER_PARTITION = "rental.kafka.maxRatePerPartition";
    String RENTAL_KAFKA_TOPIC = "rental.kafka.topic";
    String RENTAL_KAFKA_GROUP_ID = "rental.kafka.group.id";
    String RENTAL_KAFKA_AUTO_OFFSET_RESET = "rental.kafka.auto.offset.reset";
    //salehouse
    String SALE_LOCAL = "sale.local";
    String SALE_STREAMING_BATCH_DURATION = "sale.streaming.batchDuration";
    String SALE_STREAMING_CHECKPOINT_PATH = "sale.streaming.checkpoint.path";
    String SALE_STOP_PATH = "sale.stop.path";
    String SALE_KAFKA_MAX_RATE_PER_PARTITION = "sale.kafka.maxRatePerPartition";
    String SALE_KAFKA_TOPIC = "sale.kafka.topic";
    String SALE_KAFKA_GROUP_ID = "sale.kafka.group.id";
    String SALE_KAFKA_AUTO_OFFSET_RESET = "sale.kafka.auto.offset.reset";

    /**
     * 下面所有spark程序公共常量
     */
    /**
     * 环境常量
     */
    String APP_ENV = "app.env";
    String ENV_LOCAL = "local";
    String ENV_DEV = "dev";
    String ENV_PROD = "prod";
    String ENV_TEST = "test";
    /**
     * hbase相关常量
     */
    String HBASE_ZOOKEEPER_QUORUM = "hbase.zookeeper.quorum";
    String HBASE_ZOOKEEPER_PROPERTY_CLIENT_PORT = "hbase.zookeeper.property.clientPort";
    /**
     * kafka相关常量
     */
    String KAFKA_METADATA_BROKER_LIST = "kafka.metadata.broker.list";
    /**
     * hadoop相关常量
     */
    String HADOOP_NAMESERVICES = "hadoop.nameservices";
    String HADOOP_USER = "hadoop.user";
    String HADOOP_NN1 = "hadoop.nn1";
    String HADOOP_NN2 = "hadoop.nn2";
    String HADOOP_NN1_RPC = "hadoop.nn1.rpc";
    String HADOOP_NN2_RPC = "hadoop.nn2.rpc";
    /**
     * es相关常量
     */
    String ES_CLUSTER_NAME = "es.clusterName";
    String ES_PING_TIMEOUT = "es.pingTimeout";
    String ES_NODES_SAMPLER_INTERVAL = "es.nodesSamplerInterval";
    String ES_IP = "es.ip";
    String ES_PORT = "es.port";
}
